package com.eric.study.reactor.service;

import com.eric.study.reactor.entity.ReactiveMessage;
import org.springframework.stereotype.Service;
import reactor.core.publisher.Mono;

/**
 * <p> ReactiveServiceImpl.
 *
 * <p>
 * change history:
 *
 * <pre>
 * date         defect       person          comments
 * --------------------------------------------------------------------------------
 * 2023/10/18    ********     Qiheng Zhang    create file.
 * </pre>
 *
 * @author Qiheng Zhang
 * @date 2023/10/18 16:11
 * @copyright 2023, FA Software (Shanghai) Co., Ltd. All Rights Reserved.
 * @since 1.0.0
 */
@Service
public class ReactiveServiceImpl implements ReactiveService{

    @Override
    public Mono<String> getMessage() {
        return Mono.just("Hello Reactive");
    }

    @Override
    public Mono<ReactiveMessage> handleBody(ReactiveMessage message) {
        return Mono.just(message);
    }
}
